package com.yifeng.repo.flink.data.transport.dto;

import java.util.List;
import java.util.Map;

import com.alibaba.fastjson.annotation.JSONField;

import lombok.Data;

/**
 * ddl变更的数据包
 * @author lijing
 * @since 2023-04-14
 */
@Data
public class DdlDataPacket {
	/**
	 * 操作类型
	 */
	private String op;

	/**
	 * 库名
	 */
	private String database;
	
	/**
	 * 用户名
	 */
	private String schema;
	

	/**
	 * 数据库的类型，oracle、mysql
	 */
	@JSONField(name="db_type")
    private String  dbType;
	
	/**
	 * 时间戳
	 */
	@JSONField(name="ts_ms")
    private Long  tsMs;
	
	/**
	 * 表名
	 */
	private String tb;
	
	@JSONField(name="ddl_content_list")
	private List<DdlContent> ddlContentList;
	
}
